package com.guigu.springcloud.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MessageConsumer {
    // 可以自定义通道，方法类似 Stream Provider项目中的实现
    @Input
    SubscribableChannel input();
}
